package com.whoami.idmagic.idmagic

import org.apache.spark.sql.SparkSession

/**
  * v1 imei halfhour, v2onehour
  *
  * @author tzp
  * @since 2019/8/31
  */
object statistics {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession
      .builder
      .appName(s"${this.getClass.getSimpleName}")
      .getOrCreate()

    val d = spark.read.orc("/user/mz_spt/test/tzp/com.whoami.idmagic.xunji/id0903_1")
    d.rdd.keyBy(f => f.get(0))

    spark.close()
  }
}
